package com.spark.demostream.producter;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author fuqiang
 * @Description 描述
 * @Date 2020/10/23
 */
public interface SendMsg {

    String OUTPUT_CHANNEL = "output_channel";

    String INPUT_CHANNEL1 = "input_channel1";
    String INPUT_CHANNEL2 = "input_channel2";
    /**
     * 发送时间
     * @return
     */
    @Output(SendMsg.OUTPUT_CHANNEL)
    MessageChannel logoutput();

    /**
     * 接收信息
     */
    @Input(SendMsg.INPUT_CHANNEL1)
    SubscribableChannel receive1();
    /**
     * 接收信息
     */
    @Input(SendMsg.INPUT_CHANNEL2)
    SubscribableChannel receive2();
}
